import pika

# 创建连接对象，配置账号密码和地址
parameters = pika.URLParameters('amqp://xubin:bin.xu2021@192.168.1.99:5672/%2F')
connection = pika.BlockingConnection(parameters)
# 获取连接通道
channel = connection.channel()

# 在发送消息之前，我们需要确认服务于消费者的队列已经存在。
# 如果将消息发送给一个不存在的队列，RabbitMQ会将消息丢弃掉。

# 创建一个名为"hello"的队列用来将消息投递进去。发送到hello队列。
channel.queue_declare(queue='hello')
# 默认交换机比较特别，它允许我们指定消息究竟需要投递到哪个具体的队列中，队列名字需要在routing_key参数中指定。

count = 0
while True:
    if count ==1000:
        break
    channel.basic_publish(exchange='',
                          routing_key='hello',
                          body='Hello World!')
    print(" [x] Sent 'Hello World!'")
    count+=1
channel.close()
